google.golang.org/grpc.acBalancerWrapper.ac (field)
22 uses
google.golang.org/grpc (current package)
balancer_conn_wrappers.go#L311: acbw := &acBalancerWrapper{ac: ac, producers: make(map[balancer.ProducerBuilder]*refCountedProducer)}
balancer_conn_wrappers.go#L312: acbw.ac.mu.Lock()
balancer_conn_wrappers.go#L314: acbw.ac.mu.Unlock()
balancer_conn_wrappers.go#L366: ac *addrConn
balancer_conn_wrappers.go#L374: acbw.ac.cc.removeAddrConn(acbw.ac, errConnDrain)
balancer_conn_wrappers.go#L377: if !acbw.ac.tryUpdateAddrs(addrs) {
balancer_conn_wrappers.go#L378: cc := acbw.ac.cc
balancer_conn_wrappers.go#L379: opts := acbw.ac.scopts
balancer_conn_wrappers.go#L380: acbw.ac.mu.Lock()
balancer_conn_wrappers.go#L386: acbw.ac.acbw = nil
balancer_conn_wrappers.go#L387: acbw.ac.mu.Unlock()
balancer_conn_wrappers.go#L388: acState := acbw.ac.getState()
balancer_conn_wrappers.go#L389: acbw.ac.cc.removeAddrConn(acbw.ac, errConnDrain)
balancer_conn_wrappers.go#L397: channelz.Warningf(logger, acbw.ac.channelzID, "acBalancerWrapper: UpdateAddresses: failed to newAddrConn: %v", err)
balancer_conn_wrappers.go#L400: acbw.ac = newAC
balancer_conn_wrappers.go#L413: go acbw.ac.connect()
balancer_conn_wrappers.go#L419: return acbw.ac
balancer_conn_wrappers.go#L427: transport := acbw.ac.getReadyTransport()
balancer_conn_wrappers.go#L431: return newNonRetryClientStream(ctx, desc, method, transport, acbw.ac, opts...)
picker_wrapper.go#L68: ac := acw.ac